8837527e8f61bc977ffeeac6d25f32714081f6ec,modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffHeapSelfTest.java,GridCacheOffHeapSelfTest,testOffHeap,#,214

Before Change


            }

            // Query unswapped entries.
            Collection<Map.Entry<Integer, CacheValue>> res = cache.queries().
                createSqlQuery(CacheValue.class, "val >= ? and val < ?").
                execute(0, ENTRY_CNT).
                get();

            assert res.size() == ENTRY_CNT;

After Change


                }
            }, EVT_CACHE_OBJECT_TO_OFFHEAP, EVT_CACHE_OBJECT_FROM_OFFHEAP);

            IgniteCache<Integer, CacheValue> cache = grid(0).cache(null);

            populate(cache);
            evictAll(cache);

            int cnt = 0;

            for (Cache.Entry<Integer, CacheValue> e : cache.localEntries(CachePeekMode.OFFHEAP)) {
                assertEquals(e.getKey().intValue(), e.getValue().value());

                cnt++;
            }

            assertEquals(ENTRY_CNT, cnt);

            query(cache, 0, 200);        // Query swapped entries.
            unswap(cache, 200, 400);     // Check 'promote' method.
            unswapAll(cache, 400, 600);  // Check 'promoteAll' method.
            get(cache, 600, 800);        // Check 'get' method.
            peek(cache, 800, ENTRY_CNT); // Check 'peek' method in 'SWAP' mode.

            // Check that all entries were unswapped.
            for (int i = 0; i < ENTRY_CNT; i++) {
                CacheValue val = cache.localPeek(i);

                assert val != null;
                assert val.value() == i;
            }

            // Query unswapped entries.
            Collection<Cache.Entry<Integer, CacheValue>> res = cache.query(
                new SqlQuery<Integer, CacheValue>(CacheValue.class, "val >= ? and val < ?").
                setArgs(0, ENTRY_CNT)).
                getAll();

            assert res.size() == ENTRY_CNT;